package org.lxy.core.mq;

import lombok.Data;
import org.apache.rocketmq.client.consumer.MQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.MessageListener;

/**
 *
 * 消费者基本信息
 * @author 卢心怡
 */
@Data
public abstract class AbstractRocketConsumer implements RocketConsumer{

    protected String topics;
    protected String tags;
    protected MessageListener messageListener;
    protected String consumerTitel;
    protected MQPushConsumer mqPushConsumer;




    @Override
    public void registerMessageListener(String topics, String tags, String consumerTitel, MessageListener messageListener) {
        this.topics = topics;
        this.tags = tags;
        this.consumerTitel = consumerTitel;
        this.messageListener = messageListener;
    }
}
